/**
* @Title: SseController.java
* @Package com.an.controller
* @Description: TODO(用一句话描述该文件做什么)
* @author antch,861710865@qq.com
* @date 2017年7月17日 下午1:53:12
* @version V1.0
*/

package com.an.controller;

import java.util.Random;

import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

/**
 * @ClassName: SseController
 * @Description: TODO(SSE服务端发送事件，控制器)
 * @author antch,861710865@qq.com
 * @date 2017年7月17日 下午1:53:12
 *
 */
@Controller
public class SseController {

	/*
	 * text/event-stream是服务器端SSE的支持，每隔5秒向浏览器推送消息
	 *
	 */
	@RequestMapping(value = "/push", produces = "text/event-stream")
	public @ResponseBody String push() {
		Random random = new Random();
		try {
			Thread.sleep(5000);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

		String str = "data:TestTing 1,23,3" + random.nextInt() + "\n\n";
		System.out.println("SSE实现推送：：" + str);

		return str;
	}
}
